/*
package com.ruoyi.web.consumer;

import com.ruoyi.datastatistics.service.QianBaoTongService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

*/
/**
 * 千宝通通
 *
 * @author TsingYu
 * @version 1.0
 * @date 2024/10/25 10:01
 *//*

@Slf4j
@Component
@Repository
@RocketMQMessageListener(topic = "QianBaoTong_Xb_Concentrator_Topic", consumerGroup = "qianbaotong_netty")
public class QianBaoTongConsumer implements RocketMQListener<String> {

    private final QianBaoTongService qianBaoTongService;

    public QianBaoTongConsumer(QianBaoTongService qianBaoTongService) {
        this.qianBaoTongService = qianBaoTongService;
    }

    @Override
    public void onMessage(String message) {
        qianBaoTongService.callbackSubscribe(message);
    }
}
*/
